package com.example.demo.pojo;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class MessageConsumer {


//    @RabbitListener(queues = "myQueue")
//    public void receiveMessage(String message) {
//        String[] parts = message.split(":");
//        String taskId = parts[0];
//        String taskData = parts[1];
//
//        // 模拟任务处理
//        System.out.println("Processing task: " + taskId);
//        System.out.println("Task data: " + taskData);
//
//        // 这里可以执行具体的任务逻辑，比如发送邮件、处理文件等
//        // 任务完成后，可以将结果存储到数据库或通知前端
//    }
}
